package consumer;

import org.apache.rocketmq.common.message.MessageExt;

/**
 * @author : zGame
 * @version V1.0
 * @Project: rokectmqprac
 * @Package consumer
 * @Description: TODO
 * @date Date : 2022年01月11日 14:36
 */
public interface ConsumerHandler {

    public void process(byte[] body);
}
